package com.ferry.example.spring;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.CharsetUtil;

public class NettyClientHandler2 extends ChannelInboundHandlerAdapter {

    //通道就绪事件
    public void channelActive(ChannelHandlerContext ctx){

        System.out.println("NettyClientHandler2");
//        RequestPayload request = new RequestPayload();
//
//        MessageWrapper messageWrapper = new MessageWrapper();
//        //messageWrapper.setServiceMetaData();
//        messageWrapper.setAppName("ferry");
//        messageWrapper.setMethodName("getUserName");
//        messageWrapper.setArgs(null);
//        Serializer serializer = SerializerFactory.getSerializer(SerializerType.HESSIAN.getCode());
//        byte[] bytes = serializer.writeObject(messageWrapper);
//
//        request.bytes(SerializerType.HESSIAN.getCode(), bytes);
//
//        ctx.writeAndFlush(request);

        //ctx.writeAndFlush(Unpooled.copiedBuffer("老板，还钱吧",CharsetUtil.UTF_8));

        ctx.fireChannelActive();
    }

    //读取数据事件
    public void channelRead(ChannelHandlerContext ctx,Object msg){
        ByteBuf buf=(ByteBuf) msg;
        System.out.println("服务器端发来的消息："+buf.toString(CharsetUtil.UTF_8));
    }

}